package com.example.netttytest.mychat;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

public class MyChatClientHandler extends SimpleChannelInboundHandler<String> {


    /**
     * 客户端读取消息  todo 其实 所有的 逻辑 比如 与用户绑定关系 应该写在这里
     *
     * @param ctx
     * @param msg
     * @throws Exception
     */
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {

//        SocketAddress socketAddress1 = ctx.channel().remoteAddress();   //服务端的地址

        System.out.println("客户端收到："+msg.trim());

//        if (msg.contains("群发：")) {     // 没有写发送的地址,群发给其他所有客户端
//            System.out.println(msg.trim());
//        } else {
//            String address = msg.split(",")[0];
//            Channel channel = ctx.channel();
//            String localAddress = channel.localAddress().toString();
//            if (address.equalsIgnoreCase(localAddress)) {
//                System.out.println(msg.split(",")[1]);
//            }
//
//        }

    }
}
